package net.bwie.realtime.jtp.dws.trade.utils;

import org.apache.flink.table.catalog.stats.Date;

import java.text.SimpleDateFormat;
import java.util.logging.SimpleFormatter;

public class EventTimeUtil {

    private static final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    /**
     * 将时间戳格式转换位30s的时间粒度
     */

    public static String formatToHalfMinute(Long ts) {
        //ts是毫秒级的时间戳
        long seconds = ts / 1000; //把毫秒转成秒
        /**
         * 得到第几个30秒的区间，*30是回到该区间的起始秒
         */
        long halfMinute = (seconds / 30) * 30;  // 向下取整到30s

        return sdf.format(new Date(halfMinute * 1000));
    }
}
